from concurrent.futures import ThreadPoolExecutor

_executor_ = None
def init():
    global _executor_  # 声明 _executor_ 为全局变量
    _executor_ = ThreadPoolExecutor(max_workers=100)  # 创建一个线程池，最大线程数为 100

def get():
    return _executor_